package com.lefu.risk.storm.utils;

import org.apache.storm.task.TopologyContext;

public class StormCommonUtil {
	
	public static String getContextDetil(TopologyContext context){
		String pidDir = context.getPIDDir();
		String componentId = context.getThisComponentId();
		int taskId = context.getThisTaskId();
		return pidDir+"_|_"+componentId+"_|_"+taskId;
	}
}
